# _*_ coding: utf-8 _*_
# @Time : 2021/5/20 11:59 
# @Author : 钟育霖 
# @Version：V 0.1
# @File : productor.py
# @desc :
import json

import redis


if __name__ == '__main__':
    redis_0 = redis.StrictRedis(host="192.168.31.48", port=6379, db=0)
    jobs = map(lambda x: dict(job_id=x, url='https://www.aliexpress.com/item/1005002527875951.html'), range(20))
    for job in jobs:
        redis_0.rpush('todo', json.dumps(job))
